package mylab.starters.mq.impl.local;

import mylab.starters.mq.api.Message;
import mylab.starters.mq.api.Properties;
import mylab.starters.mq.impl.AbstractProducer;
import mylab.utils.common.guava.AsyncEventUtil;


public class LocalProducer extends AbstractProducer {

    public LocalProducer(Properties properties, String groupId, String clientId) {
        super(properties, groupId, clientId);
    }

    @Override
    protected void onStart() throws Exception {

    }

    @Override
    protected void onStop() throws Exception {

    }

    @Override
    protected Object onSend(Message message) throws Exception {
        AsyncEventUtil.postEvent(message);
        return null;
    }

}
